package com.sh.data.engine.domain.normalization.index.service;

import com.sh.data.engine.domain.normalization.index.model.param.IndexParam;

/**
 * @author : changkong
 * @date : 2022/12/20
 */
public interface CdmIndexTaskFlowService {
    //  @BizDataIndexAnnotation(
//          type = BizDataIndexTypeEnum.INDEX_LIB,
//          dataIdFieldName = "id",
//          dataIdParamIndex = 0,
//          operateType = BizDataIndexAnnotation.OperateType.SAVE)
    Boolean addIndex(IndexParam indexParam);

    Long createOfflineTask(Long projectId, Long pid, String name);

    Long createSqlNode(Long id, String nodeName, Long projectId, Long userId);

    void bindStartNode(Long taskId, Long sqlNode, Long projectId, Long userId);

    void initTaskFlow(Long id, Long offlineTaskId, Long sqlNodeId);
}
